/*    */ package eos.moe.dragoncore;
/*    */ 
/*    */ import java.io.IOException;
/*    */ import java.util.concurrent.ExecutorService;
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ public abstract class rh<T>
/*    */ {
/*    */   private hn w;
/*    */   private boolean q;
/*    */   private ExecutorService g;
/*    */   
/*    */   public rh(eos/moe/dragoncore/ye eos/moe/dragoncore/ye1) {
/* 16 */     this.w = eos/moe/dragoncore/ye.v(eos/moe/dragoncore/ye1);
/* 17 */     this.q = eos/moe/dragoncore/ye.v(eos/moe/dragoncore/ye1);
/* 18 */     this.g = eos/moe/dragoncore/ye.v(eos/moe/dragoncore/ye1);
/*    */   }
/*    */   
/*    */   public void z(Object object) throws pg {
/* 22 */     this.w.z();
/* 23 */     this.w.v(hn.eos/moe/dragoncore/ud.q);
/* 24 */     this.w.v(v());
/*    */     
/* 26 */     if (this.q) {
/* 27 */       long l = v((T)object);
/* 28 */       this.w.v(l);
/*    */       
/* 30 */       this.g.execute(() -> {
/*    */             try {
/*    */               z((T)object, this.w);
/* 33 */             } catch (pg pg) {
/*    */             
/*    */             } finally {
/*    */               this.g.shutdown();
/*    */             } 
/*    */           });
/*    */     } else {
/* 40 */       z((T)object, this.w);
/*    */     } 
/*    */   }
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */   
/*    */   public void v() throws pg {
/* 58 */     if (!this.w.z()) {
/*    */       return;
/*    */     }
/*    */     
/* 62 */     this.w.v(hn.eos/moe/dragoncore/ik.q);
/* 63 */     this.w.v(hn.eos/moe/dragoncore/ud.w);
/* 64 */     throw new pg("Task cancelled", pg.eos/moe/dragoncore/hd.d);
/*    */   }
/*    */   
/*    */   public abstract void v(T paramT, hn paramhn) throws IOException;
/*    */   
/*    */   public abstract long v(T paramT) throws pg;
/*    */   
/*    */   public abstract hn.eos/moe/dragoncore/mf v();
/*    */   
/*    */   public static class eos/moe/dragoncore/ye {
/*    */     private hn w;
/*    */     private boolean q;
/*    */     private ExecutorService g;
/*    */     
/*    */     public eos/moe/dragoncore/ye(ExecutorService executorService, boolean bool, hn hn1) {
/* 79 */       this.g = executorService;
/* 80 */       this.q = bool;
/* 81 */       this.w = hn1;
/*    */     }
/*    */   }
/*    */ }


/* Location:              D:\fanbian\[D][龙之核心]DragonCore-2.6.0.3.jar!\eos\moe\dragoncore\rh.class
 * Java compiler version: 8 (52.0)
 * JD-Core Version:       1.1.3
 */